/*
 ***************************************************************************************
 * All rights Reserved, Designed By RTF
 * @Title:  MessageConsumerProperties.java   
 * @Package com.rtf.repair.mq.common
 * @Description: 消费者配置属性   
 * @author: 司福林
 * @date:   2020-10-17 17:42:18   
 * @version V1.0 
 * @Copyright: 2020 RTF. All rights reserved.
 * 注意：本内容仅限于公司内部使用，禁止外泄以及用于其他的商业目
 *  ---------------------------------------------------------------------------------- 
 * 文件修改记录
 *     文件版本：         修改人：             修改原因：
 ***************************************************************************************
 */
package com.rtf.framework.mq.common;

import java.util.List;

import org.springframework.boot.context.properties.ConfigurationProperties;

import com.rtf.framework.mq.kafka.consumer.KafkaConsumerProperties;
import com.rtf.framework.mq.rocketmq.consumer.RocketMqConsumerProperties;
import com.google.common.collect.Lists;

import lombok.Data;

@ConfigurationProperties(prefix = "app.mq.consumer")
@Data
public class MessageConsumerProperties {

	/** 启用消费者 */
	private boolean enable;

	/** The rocket消费端配置. */
	private RocketMqConsumerProperties rocket = new RocketMqConsumerProperties();

	/** The kafka消费端配置. */
	private KafkaConsumerProperties kafka = new KafkaConsumerProperties();

	/** 消费者 */
	private List<ConsumerProperties> cosumer = Lists.newArrayList();
}
